package com.sh.data.engine.repository.dao.datadev.entity;

import com.baomidou.mybatisplus.annotation.TableName;
import com.sh.data.engine.common.enumDefinition.FlinkJobStatusEnum;
import com.sh.data.engine.repository.dao.base.EngineBaseModel;
import lombok.*;

import java.util.Date;

@TableName("tb_flink_job")
@Data
@EqualsAndHashCode(callSuper = true)
@AllArgsConstructor
@Builder
@NoArgsConstructor
public class FlinkJobEntity extends EngineBaseModel<FlinkJobEntity> {

    /**
     * 项目id
     */
    private Long projectId;

    /**
     * 任务节点id
     */
    private Long nodeId;

    private Long nodeConfigId;

    private String taskName;

    private Integer taskType;

    /**
     * 任务状态
     *
     * @see FlinkJobStatusEnum
     */
    private Integer status;

    /**
     * 0-手工执行 1-周期执行
     */
    private Integer execType;

    /**
     * 计划执行时间
     */
    private Date planTime;

    /**
     * 开始执行时间
     */
    private Date startTime;

    /**
     * 结束执行时间
     */
    private Date endTime;

    /**
     * 会有多个使用","
     */
    private String flinkJobId;

    /**
     * 是否关注
     */
    private Integer isAttention;
}
